# -*- coding: utf-8 -*-

import json

from task import Task


class Ppp(Task):

    def _init(self):
        super(Ppp, self)._init()

        self.__conveyor = self._components['conveyor']

    def begin(self):
        ret = [self.__conveyor.send(json.dumps({
            'status': False,
            'searchKey': u'电影',
            'crawlerSource': 'toutiao_news'
        })) for i in range(1, 10)]

        print ret
